var express = require('express');
var http    = require('http');
var io      = require('socket.io')();
var app     = express();
var server  = http.createServer(app);
server.listen(3000);
io.listen(server).on('connection', function (socket) {
//  console.log(io.sockets.sockets[socket.id].emit);
//  console.log(socket);
    socket.emit('new:msg', 'Welcome to AnonBoard');

    setInterval(function(){
        socket.emit('notification', 'hello');
    },5000);
    console.log('connect');
    socket.on('message', function (msg) {
        console.log('Message Received: ', msg);
//    console.log(io.of);
//    io.sockets[socket.id].emit('message', msg);
//    socket.join(socket.id);
//    io.to(socket.id).emit('message', msg);
        io.sockets.sockets[socket.id].emit('message', msg);
    });
    socket.on('broadcast:msg', function (data) {
        console.log(data);
        socket.broadcast.emit('new:msg', data.message);
    });
});
app.get('/', function (req, res) {
    res.send('hello world');
});
